package com.base.im.server.netty.echo;

import io.netty.channel.Channel;

import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

public final class EchoSession {
	
	//在线用户
	private static final Map<Integer, Channel>  sessionMap = new ConcurrentHashMap<Integer, Channel>();
	
	
	
	public static Channel getSession(Integer userId) {
		return sessionMap.get(userId);
	}
	
	
	
	
	public static void setSession(Integer userId,Channel channel) {
		sessionMap.put(userId, channel);
	}	
	
	
	
}
